/*     */ package com.wgcloud.task;
/*     */

import cn.hutool.core.collection.CollectionUtil;
import com.wgcloud.config.CommonConfig;
import com.wgcloud.entity.*;
import com.wgcloud.service.*;
import com.wgcloud.util.DateUtil;
import com.wgcloud.util.RestUtil;
import com.wgcloud.util.jdbc.ConnectionUtil;
import com.wgcloud.util.staticvar.BatchData;
import org.apache.commons.lang3.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

import javax.servlet.ServletContext;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

/*     */
/*     */ @Component
/*     */ public class DataScheduledTask {
/*  35 */   private Logger logger = LoggerFactory.getLogger(com.wgcloud.task.DataScheduledTask.class);
/*     */   
/*     */   @Autowired
/*     */ SystemInfoService systemInfoService;
/*     */   
/*     */   @Autowired
/*     */   DeskStateService deskStateService;
/*     */   
/*     */   @Autowired
/*     */   DeskIoService deskIoService;
/*     */   
/*     */   @Autowired
/*     */   DiskSmartService diskSmartService;
/*     */   
/*     */   @Autowired
/*     */   CpuTemperaturesService cpuTemperaturesService;
/*     */   
/*     */   @Autowired
/*     */   LogInfoService logInfoService;
/*     */   
/*     */   @Autowired
/*     */   AppInfoService appInfoService;
/*     */   @Autowired
/*     */   FileWarnInfoService fileWarnInfoService;
/*     */   @Autowired
/*     */   DockerInfoService dockerInfoService;
/*     */   @Autowired
/*     */   PortInfoService portInfoService;
/*     */   @Autowired
/*     */   FileSafeService fileSafeService;
/*     */   @Autowired
/*     */   CpuStateService cpuStateService;
/*     */   @Autowired
/*     */   MemStateService memStateService;
/*     */   @Autowired
/*     */   NetIoStateService netIoStateService;
/*     */   @Autowired
/*     */   SysLoadStateService sysLoadStateService;
/*     */   @Autowired
/*     */   TcpStateService tcpStateService;
/*     */   @Autowired
/*     */   AppStateService appStateService;
/*     */   @Autowired
/*     */   FileWarnStateService fileWarnStateService;
/*     */   @Autowired
/*     */   ShellStateService shellStateService;
/*     */   @Autowired
/*     */   HeathStateService heathStateService;
/*     */   @Autowired
/*     */   DceStateService dceStateService;
/*     */   @Autowired
/*     */   DockerStateService dockerStateService;
/*     */   @Autowired
/*     */   MailSetService mailSetService;
/*     */   @Autowired
/*     */   IntrusionInfoService intrusionInfoService;
/*     */   @Autowired
/*     */   HostGroupService hostInfoService;
/*     */   @Autowired
/*     */   DbInfoService dbInfoService;
/*     */   @Autowired
/*     */   DbTableService dbTableService;
/*     */   @Autowired
/*     */   DbTableCountService dbTableCountService;
/*     */   @Autowired
/*     */   HeathMonitorService heathMonitorService;
/*     */   @Autowired
/*     */   TaskUtilService taskUtilService;
/*     */   @Autowired
/*     */   private RestUtil restUtil;
/*     */   @Autowired
/*     */ ConnectionUtil connectionUtil;
/*     */   @Autowired
/*     */ CommonConfig commonConfig;
/*     */   @Autowired
/*     */   private ServletContext servletContext;
/*     */   
/*     */   @Scheduled(initialDelay = 29000L, fixedRate = 29000L)
/*     */   public synchronized void commitTask() {
/* 114 */     if (DateUtil.isClearTime()) {
/* 115 */       this.logger.info("正在清空历史趋势图数据，不执行提交监控数据----------" + DateUtil.getCurrentDateTime());
/* 116 */       BatchData.clearAll();
/*     */       return;
/*     */     } 
/* 119 */     this.logger.info("批量提交监控数据任务开始----------" + DateUtil.getCurrentDateTime());
/*     */     try {
/* 121 */       if (BatchData.FILEWARN_STATE_LIST.size() > 0) {
/* 122 */         List<FileWarnState> FILEWARN_STATE_LIST = new ArrayList<>();
/* 123 */         FILEWARN_STATE_LIST.addAll(BatchData.FILEWARN_STATE_LIST);
/* 124 */         BatchData.FILEWARN_STATE_LIST.clear();
/* 125 */         this.fileWarnStateService.saveRecord(FILEWARN_STATE_LIST);
/*     */       } 
/* 127 */       if (BatchData.APP_STATE_LIST.size() > 0) {
/* 128 */         List<AppState> APP_STATE_LIST = new ArrayList<>();
/* 129 */         APP_STATE_LIST.addAll(BatchData.APP_STATE_LIST);
/* 130 */         BatchData.APP_STATE_LIST.clear();
/* 131 */         this.appStateService.saveRecord(APP_STATE_LIST);
/*     */       } 
/* 133 */       if (BatchData.HEATH_STATE_LIST.size() > 0) {
/* 134 */         List<HeathState> HEATH_STATE_LIST = new ArrayList<>();
/* 135 */         HEATH_STATE_LIST.addAll(BatchData.HEATH_STATE_LIST);
/* 136 */         BatchData.HEATH_STATE_LIST.clear();
/* 137 */         this.heathStateService.saveRecord(HEATH_STATE_LIST);
/*     */       } 
/* 139 */       if (BatchData.DCE_STATE_LIST.size() > 0) {
/* 140 */         List<DceState> DCE_STATE_LIST = new ArrayList<>();
/* 141 */         DCE_STATE_LIST.addAll(BatchData.DCE_STATE_LIST);
/* 142 */         BatchData.DCE_STATE_LIST.clear();
/* 143 */         this.dceStateService.saveRecord(DCE_STATE_LIST);
/*     */       } 
/* 145 */       if (BatchData.DOCKER_STATE_LIST.size() > 0) {
/* 146 */         List<DockerState> DOCKER_STATE_LIST = new ArrayList<>();
/* 147 */         DOCKER_STATE_LIST.addAll(BatchData.DOCKER_STATE_LIST);
/* 148 */         BatchData.DOCKER_STATE_LIST.clear();
/* 149 */         this.dockerStateService.saveRecord(DOCKER_STATE_LIST);
/*     */       } 
/* 151 */       if (BatchData.CPU_STATE_LIST.size() > 0) {
/* 152 */         List<CpuState> CPU_STATE_LIST = new ArrayList<>();
/* 153 */         CPU_STATE_LIST.addAll(BatchData.CPU_STATE_LIST);
/* 154 */         BatchData.CPU_STATE_LIST.clear();
/* 155 */         this.cpuStateService.saveRecord(CPU_STATE_LIST);
/*     */       } 
/* 157 */       if (BatchData.MEM_STATE_LIST.size() > 0) {
/* 158 */         List<MemState> MEM_STATE_LIST = new ArrayList<>();
/* 159 */         MEM_STATE_LIST.addAll(BatchData.MEM_STATE_LIST);
/* 160 */         BatchData.MEM_STATE_LIST.clear();
/* 161 */         this.memStateService.saveRecord(MEM_STATE_LIST);
/*     */       } 
/* 163 */       if (BatchData.NETIO_STATE_LIST.size() > 0) {
/* 164 */         List<NetIoState> NETIO_STATE_LIST = new ArrayList<>();
/* 165 */         NETIO_STATE_LIST.addAll(BatchData.NETIO_STATE_LIST);
/* 166 */         BatchData.NETIO_STATE_LIST.clear();
/* 167 */         this.netIoStateService.saveRecord(NETIO_STATE_LIST);
/*     */       } 
/* 169 */       if (BatchData.SYSLOAD_STATE_LIST.size() > 0) {
/* 170 */         List<SysLoadState> SYSLOAD_STATE_LIST = new ArrayList<>();
/* 171 */         SYSLOAD_STATE_LIST.addAll(BatchData.SYSLOAD_STATE_LIST);
/* 172 */         BatchData.SYSLOAD_STATE_LIST.clear();
/* 173 */         this.sysLoadStateService.saveRecord(SYSLOAD_STATE_LIST);
/*     */       } 
/* 175 */       if (BatchData.LOG_INFO_LIST.size() > 0) {
/* 176 */         List<LogInfo> LOG_INFO_LIST = new ArrayList<>();
/* 177 */         LOG_INFO_LIST.addAll(BatchData.LOG_INFO_LIST);
/* 178 */         BatchData.LOG_INFO_LIST.clear();
/* 179 */         this.logInfoService.saveRecord(LOG_INFO_LIST);
/*     */       } 
/* 181 */       if (BatchData.DESK_STATE_LIST.size() > 0) {
/* 182 */         batchCommitDeskState();
/*     */       }
/* 184 */       if (BatchData.DESK_IO_LIST.size() > 0) {
/* 185 */         batchCommitDeskIo();
/*     */       }
/* 187 */       if (BatchData.DISK_SMART_LIST.size() > 0) {
/* 188 */         batchCommitDiskSmart();
/*     */       }
/* 190 */       if (BatchData.CPU_TEMPERATURES_LIST.size() > 0) {
/* 191 */         batchCommitCpuTemperatures();
/*     */       }
/* 193 */       if (BatchData.SYSTEM_INFO_LIST.size() > 0) {
/* 194 */         batchCommitSystemInfo();
/*     */       }
/* 196 */       if (BatchData.APP_INFO_LIST.size() > 0) {
/* 197 */         batchCommitAppInfo();
/*     */       }
/* 199 */       if (BatchData.FILEWARN_INFO_LIST.size() > 0) {
/* 200 */         batchCommitFileWarnInfo();
/*     */       }
/* 202 */       if (BatchData.PORT_INFO_LIST.size() > 0) {
/* 203 */         batchCommitPortInfo();
/*     */       }
/* 205 */       if (BatchData.FILE_SAFE_LIST.size() > 0) {
/* 206 */         batchCommitFileSafes();
/*     */       }
/* 208 */       if (BatchData.DOCKER_INFO_LIST.size() > 0) {
/* 209 */         batchCommitDockerInfo();
/*     */       }
/* 211 */     } catch (Exception e) {
/*     */       
/* 213 */       this.logger.error("批量提交监控数据错误", e);
/* 214 */       this.logInfoService.save("批量提交监控数据错误", e.toString(), "1");
/*     */     } 
/* 216 */     this.logger.info("批量提交监控数据任务结束----------" + DateUtil.getCurrentDateTime());
/*     */   }
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */   
/*     */   private void batchCommitCpuTemperatures() throws Exception {
/* 225 */     Map<String, Object> paramsDel = new HashMap<>();
/*     */     
/* 227 */     List<CpuTemperatures> CPU_TEMPERATURES_LIST = new ArrayList<>();
/* 228 */     CPU_TEMPERATURES_LIST.addAll(BatchData.CPU_TEMPERATURES_LIST);
/* 229 */     BatchData.CPU_TEMPERATURES_LIST.clear();
/* 230 */     List<String> hostnameList = new ArrayList<>();
/* 231 */     for (CpuTemperatures deskState : CPU_TEMPERATURES_LIST) {
/* 232 */       if (!hostnameList.contains(deskState.getHostname())) {
/* 233 */         hostnameList.add(deskState.getHostname());
/*     */       }
/*     */     } 
/* 236 */     for (String hostname : hostnameList) {
/* 237 */       paramsDel.put("hostname", hostname);
/* 238 */       this.cpuTemperaturesService.deleteByAccHname(paramsDel);
/*     */     } 
/* 240 */     this.cpuTemperaturesService.saveRecord(CPU_TEMPERATURES_LIST);
/*     */   }
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */   
/*     */   private void batchCommitDiskSmart() throws Exception {
/* 249 */     List<DiskSmart> DISK_SMART_LIST = new ArrayList<>();
/* 250 */     DISK_SMART_LIST.addAll(BatchData.DISK_SMART_LIST);
/* 251 */     BatchData.DISK_SMART_LIST.clear();
/* 252 */     List<String> hostnameList = new ArrayList<>();
/* 253 */     for (DiskSmart diskSmart : DISK_SMART_LIST) {
/* 254 */       if (!hostnameList.contains(diskSmart.getHostname())) {
/* 255 */         hostnameList.add(diskSmart.getHostname());
/*     */       }
/*     */     } 
/* 258 */     if (!CollectionUtil.isEmpty(hostnameList)) {
/* 259 */       this.diskSmartService.deleteByAccHname(hostnameList);
/*     */     }
/* 261 */     this.diskSmartService.saveRecord(DISK_SMART_LIST);
/*     */   }
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */   
/*     */   private void batchCommitDeskIo() throws Exception {
/* 270 */     List<DeskIo> DESK_IO_LIST = new ArrayList<>();
/* 271 */     DESK_IO_LIST.addAll(BatchData.DESK_IO_LIST);
/* 272 */     BatchData.DESK_IO_LIST.clear();
/* 273 */     List<String> hostnameList = new ArrayList<>();
/* 274 */     for (DeskIo deskState : DESK_IO_LIST) {
/* 275 */       if (!hostnameList.contains(deskState.getHostname())) {
/* 276 */         hostnameList.add(deskState.getHostname());
/*     */       }
/*     */     } 
/* 279 */     if (!CollectionUtil.isEmpty(hostnameList)) {
/* 280 */       this.deskIoService.deleteByAccHname(hostnameList);
/*     */     }
/* 282 */     this.deskIoService.saveRecord(DESK_IO_LIST);
/*     */   }
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */   
/*     */   private void batchCommitDeskState() throws Exception {
/* 292 */     List<DeskState> DESK_STATE_LIST = new ArrayList<>();
/* 293 */     DESK_STATE_LIST.addAll(BatchData.DESK_STATE_LIST);
/* 294 */     BatchData.DESK_STATE_LIST.clear();
/* 295 */     List<String> hostnameList = new ArrayList<>();
/* 296 */     for (DeskState deskState : DESK_STATE_LIST) {
/* 297 */       if (!hostnameList.contains(deskState.getHostname())) {
/* 298 */         hostnameList.add(deskState.getHostname());
/*     */       }
/*     */     } 
/* 301 */     if (!CollectionUtil.isEmpty(hostnameList)) {
/* 302 */       this.deskStateService.deleteByAccHname(hostnameList);
/*     */     }
/* 304 */     this.deskStateService.saveRecord(DESK_STATE_LIST);
/*     */   }
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */   
/*     */   private void batchCommitDockerInfo() throws Exception {
/* 313 */     Map<String, Object> paramsDel = new HashMap<>();
/* 314 */     List<DockerInfo> DOCKER_INFO_LIST = new ArrayList<>();
/* 315 */     DOCKER_INFO_LIST.addAll(BatchData.DOCKER_INFO_LIST);
/* 316 */     BatchData.DOCKER_INFO_LIST.clear();
/*     */     
/* 318 */     List<DockerInfo> updateList = new ArrayList<>();
/* 319 */     List<DockerInfo> savedList = this.dockerInfoService.selectAllByParams(paramsDel);
/* 320 */     for (DockerInfo systemInfo : DOCKER_INFO_LIST) {
/* 321 */       for (DockerInfo systemInfoS : savedList) {
/* 322 */         if (systemInfoS.getHostname().equals(systemInfo.getHostname()) && systemInfoS.getId().equals(systemInfo.getId())) {
/* 323 */           updateList.add(systemInfo);
/*     */         }
/*     */       } 
/*     */     } 
/*     */     
/* 328 */     this.dockerInfoService.updateRecord(updateList);
/*     */   }
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */   
/*     */   private void batchCommitAppInfo() throws Exception {
/* 337 */     Map<String, Object> paramsDel = new HashMap<>();
/* 338 */     List<AppInfo> APP_INFO_LIST = new ArrayList<>();
/* 339 */     APP_INFO_LIST.addAll(BatchData.APP_INFO_LIST);
/* 340 */     BatchData.APP_INFO_LIST.clear();
/*     */     
/* 342 */     List<AppInfo> updateList = new ArrayList<>();
/* 343 */     List<AppInfo> savedList = this.appInfoService.selectAllByParams(paramsDel);
/* 344 */     for (AppInfo systemInfo : APP_INFO_LIST) {
/* 345 */       for (AppInfo systemInfoS : savedList) {
/* 346 */         if (systemInfoS.getHostname().equals(systemInfo.getHostname()) && systemInfoS.getId().equals(systemInfo.getId())) {
/* 347 */           updateList.add(systemInfo);
/*     */         }
/*     */       } 
/*     */     } 
/*     */     
/* 352 */     this.appInfoService.updateRecord(updateList);
/*     */   }
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */   
/*     */   private void batchCommitFileWarnInfo() throws Exception {
/* 361 */     Map<String, Object> paramsDel = new HashMap<>();
/* 362 */     List<FileWarnInfo> FILEWARN_INFO_LIST = new ArrayList<>();
/* 363 */     FILEWARN_INFO_LIST.addAll(BatchData.FILEWARN_INFO_LIST);
/* 364 */     BatchData.FILEWARN_INFO_LIST.clear();
/*     */     
/* 366 */     List<FileWarnInfo> updateList = new ArrayList<>();
/* 367 */     List<FileWarnInfo> savedList = this.fileWarnInfoService.selectAllByParams(paramsDel);
/* 368 */     for (FileWarnInfo systemInfo : FILEWARN_INFO_LIST) {
/* 369 */       for (FileWarnInfo systemInfoS : savedList) {
/* 370 */         if (systemInfoS.getId().equals(systemInfo.getId())) {
/* 371 */           updateList.add(systemInfo);
/*     */         }
/*     */       } 
/*     */     } 
/*     */     
/* 376 */     this.fileWarnInfoService.updateRecord(updateList);
/*     */   }
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */   
/*     */   private void batchCommitPortInfo() throws Exception {
/* 385 */     Map<String, Object> paramsDel = new HashMap<>();
/* 386 */     List<PortInfo> PORT_INFO_LIST = new ArrayList<>();
/* 387 */     PORT_INFO_LIST.addAll(BatchData.PORT_INFO_LIST);
/* 388 */     BatchData.PORT_INFO_LIST.clear();
/*     */     
/* 390 */     List<PortInfo> updateList = new ArrayList<>();
/* 391 */     List<PortInfo> savedList = this.portInfoService.selectAllByParams(paramsDel);
/* 392 */     for (PortInfo systemInfo : PORT_INFO_LIST) {
/* 393 */       for (PortInfo systemInfoS : savedList) {
/* 394 */         if (systemInfoS.getHostname().equals(systemInfo.getHostname()) && systemInfoS.getId().equals(systemInfo.getId())) {
/* 395 */           updateList.add(systemInfo);
/*     */         }
/*     */       } 
/*     */     } 
/*     */     
/* 400 */     this.portInfoService.updateRecord(updateList);
/*     */   }
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */   
/*     */   private void batchCommitFileSafes() throws Exception {
/* 409 */     Map<String, Object> params = new HashMap<>();
/* 410 */     List<FileSafe> FILE_SAFE_LIST = new ArrayList<>();
/* 411 */     FILE_SAFE_LIST.addAll(BatchData.FILE_SAFE_LIST);
/* 412 */     BatchData.FILE_SAFE_LIST.clear();
/*     */     
/* 414 */     List<FileSafe> updateList = new ArrayList<>();
/* 415 */     List<FileSafe> savedList = this.fileSafeService.selectAllByParams(params);
/* 416 */     for (FileSafe fileSafe : FILE_SAFE_LIST) {
/* 417 */       for (FileSafe fileSafeS : savedList) {
/* 418 */         if (fileSafeS.getHostname().equals(fileSafe.getHostname()) && fileSafeS.getId().equals(fileSafe.getId())) {
/* 419 */           updateList.add(fileSafe);
/*     */         }
/*     */       } 
/*     */     } 
/*     */     
/* 424 */     this.fileSafeService.updateRecord(updateList);
/*     */   }
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */   
/*     */   private void batchCommitSystemInfo() throws Exception {
/* 433 */     Map<String, Object> paramsDel = new HashMap<>();
/* 434 */     List<SystemInfo> SYSTEM_INFO_LIST = new ArrayList<>();
/* 435 */     SYSTEM_INFO_LIST.addAll(BatchData.SYSTEM_INFO_LIST);
/* 436 */     BatchData.SYSTEM_INFO_LIST.clear();
/* 437 */     List<SystemInfo> updateList = new ArrayList<>();
/* 438 */     List<SystemInfo> insertList = new ArrayList<>();
/* 439 */     List<SystemInfo> savedList = this.systemInfoService.selectAllByParams(paramsDel);
/* 440 */     for (SystemInfo systemInfo : SYSTEM_INFO_LIST) {
/* 441 */       if (StringUtils.isEmpty(systemInfo.getHostname())) {
/*     */         continue;
/*     */       }
/* 444 */       boolean issaved = false;
/*     */       
/* 446 */       for (SystemInfo systemInfoS : savedList) {
/* 447 */         if (systemInfoS.getHostname().equals(systemInfo.getHostname())) {
/* 448 */           systemInfo.setId(systemInfoS.getId());
/* 449 */           updateList.add(systemInfo);
/* 450 */           issaved = true;
/*     */           
/*     */           break;
/*     */         } 
/*     */       } 
/* 455 */       if (!issaved) {
/* 456 */         insertList.add(systemInfo);
/*     */       }
/*     */     } 
/* 459 */     this.systemInfoService.updateRecord(updateList);
/* 460 */     this.systemInfoService.saveRecord(insertList);
/*     */   }
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */   
/*     */   @Scheduled(cron = "0 24 8 * * ?")
/*     */   public void refreshCommitDate() {
/*     */     try {
/* 471 */       this.taskUtilService.refreshCommitDate();
/* 472 */     } catch (Exception e) {
/* 473 */       this.logger.error("刷新监控数据更新时间错误", e);
/*     */     } 
/*     */   }
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */   
/*     */   @Scheduled(cron = "0 10 8 * * ?")
/*     */   public void clearHisdataTask() {
/* 483 */     if (!"master".equals(this.commonConfig.getNodeType())) {
/* 484 */       this.logger.info("slave节点不执行清空历史趋势图数据任务");
/*     */       return;
/*     */     } 
/* 487 */     this.logger.info("清空" + this.commonConfig.getHistoryDataOut() + "天前的监控历史趋势图数据");
/* 488 */     this.logger.info("定时清空历史趋势图数据任务开始----------" + DateUtil.getCurrentDateTime());
/*     */     
/* 490 */     String nowTime = DateUtil.getCurrentDateTime();
/*     */     
/* 492 */     String thrityDayBefore = DateUtil.getDateBefore(nowTime, this.commonConfig.getHistoryDataOut().intValue());
/* 493 */     Map<String, Object> paramsDel = new HashMap<>();
/*     */     try {
/* 495 */       paramsDel.put("endTime", thrityDayBefore);
/*     */       
/* 497 */       if (paramsDel.get("endTime") != null && !"".equals(paramsDel.get("endTime"))) {
/* 498 */         this.cpuStateService.deleteByAccountAndDate(paramsDel);
/* 499 */         this.memStateService.deleteByAccountAndDate(paramsDel);
/* 500 */         this.netIoStateService.deleteByAccountAndDate(paramsDel);
/* 501 */         this.sysLoadStateService.deleteByAccountAndDate(paramsDel);
/* 502 */         this.appStateService.deleteByDate(paramsDel);
/* 503 */         this.dockerStateService.deleteByDate(paramsDel);
/* 504 */         this.deskStateService.deleteByAccountAndDate(paramsDel);
/* 505 */         this.deskIoService.deleteByAccountAndDate(paramsDel);
/* 506 */         this.diskSmartService.deleteByAccountAndDate(paramsDel);
/* 507 */         this.cpuTemperaturesService.deleteByAccountAndDate(paramsDel);
/* 508 */         this.heathStateService.deleteByDate(paramsDel);
/* 509 */         this.dceStateService.deleteByDate(paramsDel);
/* 510 */         this.logInfoService.deleteByDate(paramsDel);
/* 511 */         this.dbTableCountService.deleteByDate(paramsDel);
/* 512 */         this.fileWarnStateService.deleteByDate(paramsDel);
/* 513 */         this.shellStateService.deleteByDate(paramsDel);
/*     */         
/* 515 */         this.logInfoService.save("定时清空历史趋势图数据完成", "每天8:10清空" + this.commonConfig.getHistoryDataOut() + "天前的监控历史趋势图数据，任务完成", "1");
/*     */       
/*     */       }
/*     */ 
/*     */     
/*     */     }
/* 521 */     catch (Exception e) {
/* 522 */       this.logger.error("定时清空历史趋势图数据任务出错", e);
/* 523 */       this.logInfoService.save("定时清空历史趋势图数据错误", e.toString(), "1");
/*     */     } 
/* 525 */     this.logger.info("定时清空历史趋势图数据任务结束----------" + DateUtil.getCurrentDateTime());
/*     */   }
/*     */ }


/* Location:              /Users/zhangyongxin/soft-install/wgcloud/wgcloud-v3.3.5/server/bank/wgcloud-server-release.jar!/BOOT-INF/classes/com/wgcloud/task/DataScheduledTask.class
 * Java compiler version: 8 (52.0)
 * JD-Core Version:       1.1.3
 */